package com.hbase;

import com.until.HBUtils;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.util.Bytes;

import java.io.IOException;

/**
 * @Author：YuanHaHa
 * @Date：2024/7/5 22:04
 */
public class PutTableData {
    public static void main(String[] args) throws IOException {
        // 1.获取 Hbase 连接对象
        Connection connection = HBUtils.getConnection();
        // 过时 API
        // HTable personTable = new HTable(connection.getConfiguration(), TableName.valueOf("Person"));
        // 2.获取 Table 对象
        Table personTable = connection.getTable(TableName.valueOf("Person"));
        // 3.创建 Put 对象 添加的数据是 封装在 put 对象中的
        Put put = new Put(Bytes.toBytes("1001"));
        // 4.添加数据 对应格式 => 列族 , 列名 , 值
        put.addColumn(Bytes.toBytes("info01"), Bytes.toBytes("name"), Bytes.toBytes("李白"));
        put.addColumn(Bytes.toBytes("info01"), Bytes.toBytes("age"), Bytes.toBytes("19"));
        put.addColumn(Bytes.toBytes("info01"), Bytes.toBytes("sex"), Bytes.toBytes("男"));
        // 5.添加数据
        personTable.put(put);
        System.out.println("添加成功");
        // 6.释放连接
        HBUtils.release(connection, null);
    }
}
